package org.jeecg.modules.common.service;

import io.swagger.models.auth.In;
import org.jeecg.modules.common.bean.mqtt.*;

public interface MqttService {

    void addSubscribeTopic(String subscribeTopic);

    void removeSubscribeTopic(String subscribeTopic);

    void sendMessage(String topic, String payload, Integer qos);

    void reboot(String topic,Integer qos);

    void setCyc(String topic, Integer qos, MqttSysBean mqttSettingBean);

    void setThv(String topic, Integer qos, MqttThresholdBean mqttThresholdBean);

    void setAI(String topic, Integer qos, MqttAIBean mqttAIBean);

    void setDI(String topic, Integer qos, MqttDiBean mqttDiBean);

    void setCMD(String topic, Integer qos, String cmd);

    void control(String devicePid, Integer qos,MqttControlBean mqttControlBean);
}

